import oss2
import requests
from finance_c2c.settings import OssAccessKey, OssAccessSecret
from core.tools.func_utils import funcUtils
OssUrl = "https://oss.kalaibao.com/"


def oss_upload_file(data, path="coffee/WxaCod/"):
    # 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
    auth = oss2.Auth(OssAccessKey, OssAccessSecret)
    # Endpoint以杭州为例，其它Region请按实际情况填写。
    bucket = oss2.Bucket(auth, 'http://oss-cn-beijing.aliyuncs.com', 'zaoqi')

    # requests.get返回的是一个可迭代对象（Iterable），此时Python SDK会通过Chunked Encoding方式上传。
    file_name = path + funcUtils.unique_value + ".jpg"
    result = bucket.put_object(file_name, data)
    print(result)
    print(result.status)
    return OssUrl + file_name


def upload_network_file(url, path="womai/"):
    # 阿里云主账号AccessKey拥有所有API的访问权限，风险很高。强烈建议您创建并使用RAM账号进行API访问或日常运维，请登录 https://ram.console.aliyun.com 创建RAM账号。
    auth = oss2.Auth(OssAccessKey, OssAccessSecret)
    # Endpoint以杭州为例，其它Region请按实际情况填写。
    bucket = oss2.Bucket(auth, 'http://oss-cn-beijing.aliyuncs.com', 'zaoqi')

    # requests.get返回的是一个可迭代对象（Iterable），此时Python SDK会通过Chunked Encoding方式上传。
    input = requests.get(url)
    file_name = url.split("com/")[1]
    file_name = path + file_name
    bucket.put_object(file_name, input)


if __name__ == '__main__':
    upload_network_file("http://pic1.womai.com/upload/601/603/606/66102/214300/10261990/10261990_1_pic270_5649.jpg")
